package com.ferry.transport.netty.consumer;

public interface ConnectionWatcher {

        void start();

        boolean waitForAvailable(long timeoutMillis);
}